package com.ubtechinc.cruzr.launcher2.model.helper;

import org.reactivestreams.Subscription;

import io.reactivex.FlowableSubscriber;

public abstract class SimpleFlowableSubscribe<T> implements FlowableSubscriber<T> {
    @Override
    public void onSubscribe(Subscription s) {
        s.request(1);
    }

    @Override
    public void onError(Throwable t) {
        t.printStackTrace();
    }

    @Override
    public void onComplete() {

    }
}
